package com.shanks.framework.mq.repository;

import com.shanks.framework.mq.domain.MQMessage;
import com.shanks.framework.mq.model.MessageConsumeExceptionRecordPO;
import com.shanks.framework.mq.model.MessageConsumeRecordPO;

public interface MessageConsumeRecordRepository {
    Boolean selectByMessage(MQMessage mqMessage);

    /**
     * 通过校验码查询
     * @param checkCode
     * @return
     */
    Boolean selectByCheckCode(String checkCode);

    /**
     * 新增消费记录
     * @param messageConsumeRecordPO
     */
    void insert(MessageConsumeRecordPO messageConsumeRecordPO);

}
